package org.tao.lightningmq.client.consumer;

import java.util.List;

/**
 * @Author lht
 * @date 2025/1/19 - 19:26
 * @description: broker消费监听器
 */
@FunctionalInterface
public interface MessageConsumeListener {

    /**
     * 默认的消费处理函数
     *
     * @param consumeMessages
     * @return
     */
    ConsumeResult consume(List<ConsumeMessage> consumeMessages) throws InterruptedException;

}
